package org.wj.config

import org.apache.spark.sql.SparkSession

trait LocalSparkSession extends App {

  val spark: SparkSession = SparkSession.builder().master("local").appName(super.getClass.getName).getOrCreate()

  abstract override def main(args: Array[String]): Unit = {
    super.main(args)
    spark.stop()
  }
}
